package mya.mes.mdc.share.mqttread;

import mya.mes.mdc.share.plc.PlcTagVoProcessor;
import mya.mes.mdc.share.vo.mqtt.MqttMsgReceived;

public interface MqttMsgProcessor {

    public Boolean accept(Long zoneId);

    public void mqttReceive(MqttMsgReceived mqttMsg) throws Exception;

    public default void addPlcTagVoProcessor(PlcTagVoProcessor processor) {

    }

    public default void removePlcTagVoProcessor(PlcTagVoProcessor processor) {

    }

}
